micro_utils.dokka/dev.inmo.micro_utils.repos.cache/[jvm]WriteCRUDCacheRepo

WriteCRUDCacheRepo

open class WriteCRUDCacheRepo<ObjectType, IdType, InputValueType>( parentRepo: WriteCRUDRepo<ObjectType, IdType, InputValueType>, kvCache: KVCache<IdType, ObjectType>, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), idGetter: (ObjectType) -> IdType) : WriteCRUDRepo<ObjectType, IdType, InputValueType> , CacheRepo

Constructors

WriteCRUDCacheRepo

fun <ObjectType, IdType, InputValueType> WriteCRUDCacheRepo( parentRepo: WriteCRUDRepo<ObjectType, IdType, InputValueType>, kvCache: KVCache<IdType, ObjectType>, scope: CoroutineScope = CoroutineScope(Dispatchers.Default), idGetter: (ObjectType) -> IdType)

Functions

open suspend override fun create(values: List<InputValueType>): List<ObjectType>

open suspend override fun deleteById(ids: List<IdType>)

open suspend override fun update(values: List<UpdatedValuePair<IdType, InputValueType>>): List<ObjectType>

open suspend override fun update(id: IdType, value: InputValueType): ObjectType?

Properties

createdObjectsFlowJob

val createdObjectsFlowJob: Job

deletedObjectsFlowJob

val deletedObjectsFlowJob: Job

deletedObjectsIdsFlow

open override val deletedObjectsIdsFlow: Flow<IdType>

open override val newObjectsFlow: Flow<ObjectType>

updatedObjectsFlow

open override val updatedObjectsFlow: Flow<ObjectType>

updatedObjectsFlowJob

val updatedObjectsFlowJob: Job